/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package multithread;

import java.util.concurrent.BlockingQueue;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author NDA
 */
public class NguoiCungCap implements Runnable {

    private BlockingQueue<String> kho = null;

    public NguoiCungCap(BlockingQueue<String> kho) {
        this.kho = kho;
    }

    @Override
    public  synchronized void run() {
        while (true) {
            System.out.println("       Người cung cấp và chủ kho");
            System.out.println("Người cung cấp: Bác chủ kho ơi, em giao hàng");
            System.out.println("Chủ kho       : Uh, cho hàng vào kho đi!");
            System.out.println("---------------------------------------------------");

            try {
                kho.put("hàng nè!");
                System.out.println("Trong kho hiện tại có: " + kho.size() + " kiện hàng");
                System.out.println("---------------------------------------------------");
                Thread.sleep(5000);
            } catch (InterruptedException ex) {
                Logger.getLogger(NguoiCungCap.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
}
